# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.bash import BashOperator

from spmi.time_sensor import time_after_01_00

spmi_ods__spmi_apack_bill = BashOperator(
    task_id='spmi_ods__spmi_apack_bill',
    execution_timeout=timedelta(hours=2),
    retries=2,
    email=['lukunming@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="spmi/ods/mysql/spmi/spmi_apack_bill/execute.sh",
    pool='spmi_apack',
    pool_slots=1,
)


spmi_ods__spmi_apack_bill << time_after_01_00

